package net.jcip.examples.chapter7;

import java.io.PrintWriter;
import java.io.Writer;
import java.util.concurrent.*;

/**
 * LogWriter
 * <p/>
 * Producer-consumer logging service with no shutdown support
 *
 * @author Brian Goetz and Tim Peierls
 */

/**
 * LinkedBlockingQueue 是基于链表实现的阻塞队列，支持可选的容量限制。其主要特性包括：
 *
 * 容量限制：可以在初始化时指定容量，未指定时默认为 Integer.MAX_VALUE。
 * 线程安全：通过内部锁实现线程安全。
 * 阻塞操作：提供阻塞的 put 和 take 方法，当队列已满或为空时，会阻塞当前线程。
 * 主要用法：
 * 适用于生产者-消费者模型。
 * 用于需要容量限制和阻塞操作的场景。
 */

/**
 *BlockingQueue 是一个接口，定义了一组阻塞队列操作方法。它有多个实现类，包括：
 *
 * ArrayBlockingQueue
 * LinkedBlockingQueue （ArrayBlockingQueue 与LinkedBlockingQueue 讲解： https://segmentfault.com/a/1190000044299192）
 * PriorityBlockingQueue
 * DelayQueue
 * SynchronousQueue
 *
 * 主要特性：
 * 阻塞操作：定义了 put、take、offer、poll 等阻塞方法。
 * 线程安全：所有实现类都保证线程安全。
 * 主要用法：
 * 定义通用的阻塞队列操作。
 * 具体使用时选择适合的实现类。
 *
 */

/**
 * ConcurrentLinkedQueue 是基于链表的无界非阻塞队列，使用 CAS 操作实现线程安全。
 *
 * 主要特性：
 * 无界：没有容量限制。
 * 非阻塞：不提供阻塞操作，所有方法都是非阻塞的。
 * 高性能：适用于高并发场景。
 * 主要用法：
 * 适用于不需要容量限制和阻塞操作的高并发环境。
 * 常用于缓存、任务管理等场景。
 */
public class LogWriter {
    private final BlockingQueue<String> queue;
    private final LoggerThread logger;
    private static final int CAPACITY = 1000;

    public LogWriter(Writer writer) {
        this.queue = new LinkedBlockingQueue<String>(CAPACITY);
        this.logger = new LoggerThread(writer);
    }

    public void start() {
        logger.start();
    }

    public void log(String msg) throws InterruptedException {
        queue.put(msg);
    }

    private class LoggerThread extends Thread {
        private final PrintWriter writer;

        public LoggerThread(Writer writer) {
            this.writer = new PrintWriter(writer, true); // autoflush
        }

        public void run() {
            try {
                while (true)
                    writer.println(queue.take());
            } catch (InterruptedException ignored) {
                //当捕获到中止标识时取消日志线程
            } finally {
                writer.close();
            }
        }
    }
}
